package com.zt.bigdata.spark.dataalgorithms.chapter04

import com.zt.bigdata.spark.Constant

/**
  *
  */
object Main {
  def main(args: Array[String]): Unit = {
    var parameter = Parameter("local[2]",
      s"${Constant.BASE_PATH}/chapter04left.csv",
      s"${Constant.BASE_PATH}/chapter04right.csv")
    new LeftJoinRDD()
      .setAppName("LeftJoinSql")
      .process(parameter)


  }
}
